package com.xm.rabbitmq.dto.mq.pipeline;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author 小木
 * @date 2021/4/20
 * @desc UserEvent 消息管道
 */
public interface UserEventPipeline {

    String SEND = "user_event_send";
    String RECV = "user_event_recv";

    @Output(SEND)
    MessageChannel sendChannel();

    @Input(RECV)
    SubscribableChannel recvChannel();
}
